import { RunnablePassthrough } from "@langchain/core/runnables";

const logger = new RunnablePassthrough({
  // 一个副作用函数
  func: async (input) => {
    console.log("收到输入：", input);
    // 对输入做一些副作用处理，例如记录日志、写入数据库、做埋点等
  },
});

const res = await logger.invoke("LangChain");
console.log(res);
